package com.dog.framework.mqtt.component;


import com.dog.framework.mqtt.domain.IotMessage;

/**
 * <p>
 * Mqtt消息订阅
 * </p>
 *
 * @author liuxk
 * @since 2023/11/21
 */
public interface IMqttListener {

    /**
     * 消息消费
     *
     * @param message
     */
    void consume(IotMessage message);

}
